const s = require('../server');
const tp = require('../tcppk');
const sr = new s({
    host: '0.0.0.0',
    port: '9808',
});
sr.getSk((sk, sockets) => {
    const sv = new tp();

    sv.get(sk, sockets, (data) => {
        //console.log(data);
        // 接受订阅的消息
        console.log(data.toString("utf8"));

        // 发送消息
        // 写入一个整包
        const sql = sv.encodeMsg("str");
        // sk.write(sql);

        //写出半个包在来半个包
        // const hd = Buffer.allocUnsafe(4);
        // hd.writeInt32LE(Buffer("str").length);
        // sk.write(hd);

        // setTimeout(() => {
        //     sk.write(Buffer("str"));
        // },4000)

        // 写一个半包在写半包
        // const hd = Buffer.allocUnsafe(4);
        // hd.writeInt32LE(Buffer("str").length);
        // sk.write(Buffer.concat([sql, hd], sql.length+hd.length));

        // setTimeout(() => {
        //     sk.write(Buffer("str"));
        // },4000)

        // 写出两个整包
        //sk.write(Buffer.concat([sql, sql], sql.length+sql.length));

        // json
        const a = {
            a:1,
            b:2,
        }
        sk.write(sv.encodeMsg(JSON.stringify(a)));

    });
})


